multinode cluster kafka consumer